import HDFS

if __name__ == '__main__':
    hdfs = HDFS.HDFS()
    # 创建保存的文件夹
    # hdfs.createDir('/doubanData')
    # 上传处理好的数据文件到hadoop上
    # hdfs.uploadFile('../Data/zhangjinyang/mean/grade_mean.csv', '/doubanData/grade_mean.csv')
    # hdfs.uploadFile('../Data/zhangjinyang/sum/talk_sum.csv', '/doubanData/talk_sum.csv')
    # hdfs.uploadFile('../Data/zhangjinyang/talk/literature_counts.csv', '/doubanData/literature_counts.csv')
    # hdfs.uploadFile('../Data/zhangjinyang/talk/novel_counts.csv', '/doubanData/novel_counts.csv')
    # hdfs.uploadFile('../Data/zhangjinyang/talk/poetry_counts.csv', '/doubanData/poetry_counts.csv')
    # hdfs.uploadFile('../Data/zhangjinyang/talk/prose_counts.csv', '/doubanData/prose_counts.csv')
    hdfs.uploadFile('E:\\学习\\融创大数据实训\\实训大作业\\Douban\\folk_music\\folk_music\\song_counts.csv', '/doubanData/song_counts.csv')
    hdfs.uploadFile('E:\\学习\\融创大数据实训\\实训大作业\\Douban\\folk_music\\folk_music\\top_10_high_rating_music.csv', '/doubanData/top_10_high_rating_music.csv')
    hdfs.uploadFile('E:\\学习\\融创大数据实训\\实训大作业\\Douban\\folk_music\\folk_music\\不同种类的音乐的评价人数.csv', '/doubanData/不同种类的音乐的评价人数.csv')